package com.yl.ydk.base

import rx.Observable
import rx.android.schedulers.AndroidSchedulers
import rx.schedulers.Schedulers


object RxHelper {

    fun <T> applySchedulers(): Observable.Transformer<T, T>? {
        return Observable.Transformer<T, T> { observable ->
            observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
        }
    }


}